package com.fulin.thread.queue.delayqueue;

import java.util.concurrent.DelayQueue;

/**
*
* @description 
* @auther fulin16@crnet.com.hk
* @since 2019年4月13日 下午3:35:01
*
*/
public class Cache {
	private static DelayQueue<Message> queue = new DelayQueue<Message>(); 
	
	public static void put(Message message){
		queue.put(message);
	}
	
	public static Message take() throws InterruptedException{
		return queue.take();
	}
	
	public static int size(){
		return queue.size();
	}
}
